package com.ruoyi.system.controller;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.nacos.common.utils.StringUtils;
import com.alipay.api.AlipayApiException;
import com.alipay.api.AlipayClient;
import com.alipay.api.DefaultAlipayClient;
import com.alipay.api.request.AlipaySystemOauthTokenRequest;
import com.alipay.api.request.AlipayTradePagePayRequest;
import com.alipay.api.request.AlipayUserInfoShareRequest;
import com.alipay.api.response.AlipaySystemOauthTokenResponse;
import com.alipay.api.response.AlipayUserInfoShareResponse;
import com.ruoyi.system.config.AlipayConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

/**
 * @program: ruoyi
 * @description: 测试支付宝支付的接口/pay的类
 * @author: yanghua
 * @create: 2020-09-22 17:57
 **/
@RestController
@RequestMapping("/pay")
public class PayController {
    private static final Logger log = LoggerFactory.getLogger(PayController.class);

    @PostMapping("/payDemo")
    public void payController(HttpServletRequest request, HttpServletResponse response) throws IOException {
        //获得初始化的AlipayClient
        AlipayClient alipayClient = new DefaultAlipayClient(AlipayConfig.gatewayUrl, AlipayConfig.APP_ID, AlipayConfig.APP_PRIVATE_KEY, "json", AlipayConfig.CHARSET, AlipayConfig.ALIPAY_PUBLIC_KEY, AlipayConfig.sign_type);
        //扔到业务逻辑层，进行处理：参数校验，避免金额改写**，校验订单状态，是否符合支付可销售状态


        //设置请求参数
        AlipayTradePagePayRequest alipayRequest = new AlipayTradePagePayRequest();
        alipayRequest.setReturnUrl(AlipayConfig.return_url);
        alipayRequest.setNotifyUrl(AlipayConfig.notify_url);

        //商户订单号，商户网站订单系统中唯一订单号，必填
        String out_trade_no = new String(request.getParameter("WIDout_trade_no").getBytes("ISO-8859-1"), "UTF-8");
        //付款金额，必填
        String total_amount = new String(request.getParameter("WIDtotal_amount").getBytes("ISO-8859-1"), "UTF-8");
        //订单名称，必填
        String subject = new String(request.getParameter("WIDsubject").getBytes("ISO-8859-1"), "UTF-8");
        //商品描述，可空
        String body = new String(request.getParameter("WIDbody").getBytes("ISO-8859-1"), "UTF-8");

        alipayRequest.setBizContent("{\"out_trade_no\":\"" + out_trade_no + "\","
                + "\"total_amount\":\"" + total_amount + "\","
                + "\"subject\":\"" + subject + "\","
                + "\"body\":\"" + body + "\","
                + "\"product_code\":\"FAST_INSTANT_TRADE_PAY\"}");

        //若想给BizContent增加其他可选请求参数，以增加自定义超时时间参数timeout_express来举例说明
        //alipayRequest.setBizContent("{\"out_trade_no\":\""+ out_trade_no +"\","
        //		+ "\"total_amount\":\""+ total_amount +"\","
        //		+ "\"subject\":\""+ subject +"\","
        //		+ "\"body\":\""+ body +"\","
        //		+ "\"timeout_express\":\"10m\","
        //		+ "\"product_code\":\"FAST_INSTANT_TRADE_PAY\"}");
        //请求参数可查阅【电脑网站支付的API文档-alipay.trade.page.pay-请求参数】章节

        //请求
        String form = "";
        try {
            form = alipayClient.pageExecute(alipayRequest).getBody(); //调用SDK生成表单
        } catch (AlipayApiException e) {
            e.printStackTrace();
        }
        response.setContentType("text/html;charset=" + AlipayConfig.CHARSET);
        response.getWriter().write(form);//直接将完整的表单html输出到页面
        response.getWriter().flush();
        response.getWriter().close();
        //支付完毕，调用订单审批流，修改订单状态

    }

    /**
     * 描述：登录接口改写在alipaylogincontroller里面了。业务逻辑更加清晰，并指明了成功获取用户信息后的跳转地址。
     *
     * @param request
     * @return
     */
    @RequestMapping("/zfbLogin")
    public String zfbLogin(HttpServletRequest request) {

        // 获取AuthCode 等，具体可以获取哪些数据参考支付宝官方接口文档，这里只需要使用auth_code
        String authCode = request.getParameter("auth_code");
        String app_auth_code = request.getParameter("app_auth_code");
        log.info("authCode ==> " + authCode);
        log.info("app_auth_code ==> " + app_auth_code);
        if (StringUtils.isNotEmpty(authCode)) {
            try {
                // 这些参数均被抽取出来，参数说明见博客
                AlipayClient alipayClient = new DefaultAlipayClient(AlipayConfig.gatewayUrl, AlipayConfig.APP_ID, AlipayConfig.APP_PRIVATE_KEY, "json", AlipayConfig.CHARSET, AlipayConfig.ALIPAY_PUBLIC_KEY, AlipayConfig.sign_type);

                // 通过authCode获取accessToken
                AlipaySystemOauthTokenRequest oauthTokenRequest = new AlipaySystemOauthTokenRequest();
                oauthTokenRequest.setCode(authCode);
                oauthTokenRequest.setGrantType("authorization_code");
                AlipaySystemOauthTokenResponse oauthTokenResponse = alipayClient.execute(oauthTokenRequest);
                String accessToken = oauthTokenResponse.getAccessToken();
                log.info("accessToken ==> " + accessToken);


                if (StringUtils.isNotEmpty(accessToken)) {
                    // 根据accessToken获取用户信息
                    AlipayUserInfoShareResponse userInfoResponse = alipayClient.execute(new AlipayUserInfoShareRequest(), accessToken);
                    if (userInfoResponse.isSuccess()) {
                        log.info("zfbUser ==> " + JSONObject.toJSONString(userInfoResponse));
                        // userInfoResponse 中有哪些用户信息参考支付宝官方接口文档，这里演示如下几个
                        Map userInfo = new HashMap(6);
                        userInfo.put("nickname", userInfoResponse.getNickName());
                        log.info("nickname = " + userInfoResponse.getNickName());
                        userInfo.put("imgUrl", userInfoResponse.getAvatar());
                        log.info("imgUrl = " + userInfoResponse.getAvatar());
                        userInfo.put("uuid", userInfoResponse.getUserId());
                        log.info("userid = " + userInfoResponse.getUserId());
                        // 接下来你可以通过免密登录或者获取密码自动登录等方式，做登录操作获取进入首页即可
                        /*
                        将获取的token和用户信息存入redis，并绑定一个对应的角色
                        token存入redis，是为了和前端请求比较，进行认证
                        绑定角色，是给这个扫码登录的用户一个身份，指明他的数据权限范围
                        缓存用户信息，就是为了他的个人中心和订单服务
                         */


                        return "index";
                    } else {
                        log.info("无法获取用户信息");
                    }
                } else {
                    log.info("接入支付宝登录认证出现错误，无法获取到accessToken.");
                }
            } catch (Exception e) {
                log.info("获取支付宝用户信息失败");
                e.printStackTrace();
            }
        } else {
            log.info("接入支付宝登录回调方法错误，无法获取到Token.");
        }
        return "login";
    }
}
